package com.aqielife.common.thread;

import reactor.core.scheduler.NonBlocking;

/**
 * @author aqie
 * @date 2022/02/05 12:51
 * @desc
 */
public final class NonBlockingThread extends Thread implements NonBlocking {
  public NonBlockingThread(Runnable target, String name) {
    super(target, name);
  }

  public static boolean isInNonBlockingThread() {
    return Thread.currentThread() instanceof NonBlocking;
  }
}
